<?php
namespace app\job;

use think\queue\Job;
use app\api\service\OrderServer;

class SendWechatMessage
{
    public function fire(Job $job, $orderData)
    {
        try {
            // 执行发送微信消息
            OrderServer::sendWechatMessageToMasters($orderData);

            // 任务执行成功后删除任务
            $job->delete();
        } catch (\Exception $e) {
            // 记录错误日志
            trace('微信消息发送失败: ' . $e->getMessage(), 'error');

            // 根据需要决定是否重试
            if ($job->attempts() > 3) {
                // 重试次数超过3次，删除任务
                $job->delete();
            } else {
                // 1秒后重试
                $job->release(1);
            }
        }
    }
}
